var mysql = require('mysql')
var pool = mysql.createPool({
    host: 'localhost',  // 连接的数据库服务器
    user: 'root',       // 用户名
    password: 'root',       // 密码
    database: 'chunyu'        // 数据库名
})

const query = async (sql, params) => {
    return await new Promise((resolve, reject) => {
        pool.query(sql, params, function (err, res) {
            if (err) {
                reject(err)
            } else {
                resolve(res)
            }
        })
    })
}

module.exports = query